package com.dx.chat.kafka.config.service;

import org.apache.kafka.common.PartitionInfo;

import java.util.List;

/**
 * kafka 生产者接口
 */
public interface IKafkaProducerService {
    void sendMessage(String topic, String message);

    void sendMessage(String topic, String key, String message);

    List<PartitionInfo> partitionsFor(String topic);
}
